#!usr/bin/env python  
# -*- coding:utf-8 _*-
""" 
@author:robot
@file: relation.py 
@version:
@time: 2022/01/06 
"""
from TapException.TM import DataFlowRelationBuildError

class V2DataFlowMapTable:
    """
    迁移任务 sink 配置
    """

    def __init__(self, kwargs):
        self.syncObjects = kwargs.get('syncObjects', {})
        if type(self.syncObjects) is not dict:
            raise DataFlowRelationBuildError
        self.tablePrefix = kwargs.get('table_prefix', '')
        self.tableSuffix = kwargs.get('table_suffix', '')
        self.tableNameTransform = kwargs.get('tableNameTransform', '')
        self.fieldsNameTransform = kwargs.get('fieldsNameTransform', '')
